package qc.common.core.constants;

/**
 * QMS消息队列静态定义
 *
 * @author QuCheng Tech
 * @since 2025/8/15
 */
public interface QmsMQConstant {
    /**
     * 消息队列--原始报文主题
     */
    String MQ_RAWPACKETS_TOPIC = "t_rawpackets";

    /**
     * 消息队列--消费者分组；原始报文消费者组
     */
    String MQ_RAWPACKETS_CONSUMER_GROUP = "g_rawpackets";

    /**
     * 消息队列--原始数据主题
     */
    String MQ_RAWDATA_TOPIC = "t_rawdata";

    /**
     * 消息队列--消费者分组；原始数据计算消费者组
     */
    String MQ_RAWDATA_CONSUMER_CALC_GROUP = "g_rawdata_calc";

    /**
     * 消息队列--消费者分组；原始数据保存至数据库消费者组
     */
    String MQ_RAWDATA_CONSUMER_SAVETODB_GROUP = "g_rawdata_save";

    /**
     * 消息队列--点号数据主题
     */
    String MQ_POINTDATA_TOPIC = "t_pointdata";

    /**
     * 消息队列--消费者分组；点号数据触发关联点号计算消费者组
     */
    String MQ_POINTDATA_CONSUMER_CALC_GROUP = "g_pointdata_calc";

    /**
     * 消息队列--消费者分组；点号数据预警消费者组
     */
    String MQ_POINTDATA_CONSUMER_ALARM_GROUP = "g_pointdata_alarm";

    /**
     * 消息队列--消费者分组；点号数据日志记录消费者组
     */
    String MQ_POINTDATA_CONSUMER_LOG_GROUP = "g_pointdata_log";

    /**
     * 消息队列--人工重新计算/统计点号数据主题
     */
    String MQ_MANUALCALC_TOPIC = "t_pointdata_manualcalc";

    /**
     * 消息队列--人工维护点号数据主题
     */
    String MQ_MANUALMANAGE_TOPIC = "t_pointdata_manualmanage";

    /**
     * 消息队列--QMS数据流程日志主题
     */
    String MQ_LOG_DATAFLOW_TOPIC = "t_log_dataflow";

    /**
     * 消息队列--消费者分组；数据流程日志保存至数据库消费者组
     */
    String MQ_LOG_DATAFLOW_CONSUMER_SAVETODB_GROUP = "g_log_dataflow_save";

    /**
     * 消息队列--处理原始数据人工任务主题
     */
    String MQ_MANUALTASK_PROCESSRAWDATA_TOPIC = "t_manualtask_processrawdata";

    /**
     * 消息队列--消费者分组；处理原始数据人工任务消费者组
     */
    String MQ_MANUALTASK_PROCESSRAWDATA_CONSUMER_GROUP = "g_manualtask_processrawdata";
    /**
     * 消息队列--计算点号数据人工任务主题
     */
    String MQ_MANUALTASK_CALCPOINTDATA_TOPIC = "t_manualtask_calcpointdata";

    /**
     * 消息队列--消费者分组；计算点号数据人工任务消费者组
     */
    String MQ_MANUALTASK_CALCPOINTDATA_CONSUMER_GROUP = "g_manualtask_calcpointdata";
    /**
     * 消息队列--转发点号数据人工任务主题
     */
    String MQ_MANUALTASK_FORWARDPOINTDATA_TOPIC = "t_manualtask_forwardpointdata";

    /**
     * 消息队列--消费者分组；转发点号数据人工任务消费者组
     */
    String MQ_MANUALTASK_FORWARDPOINTDATA_CONSUMER_GROUP = "g_manualtask_forwardpointdata";
}
